package com.xiliu.rocketmq;

import org.apache.rocketmq.client.exception.MQClientException;
import org.apache.rocketmq.client.producer.DefaultMQProducer;

/**
 * @author xiliu
 * @description 创建主题 demo
 * @date 2022/3/1
 */
public class TopicDemo {

    public static void main(String[] args) throws MQClientException{
        // 创建一个生产者组
        DefaultMQProducer producer = new DefaultMQProducer("xiliu_producer_group");
        // 生产者需用通过NameServer获取所有broker的路由信息，多个用分号隔开
        producer.setNamesrvAddr("42.194.222.32:9876");
        // 启动
        producer.start();

        // 创建topic  key：broker名称  newTopic：topic名称  queueNum：队列数（分区）
        producer.createTopic("broker_xiliu", "xiliu_topic", 8);

        System.out.println("创建topic成功");

        producer.shutdown();
    }
}
